package com.zh.common.service;

/**
 * RabbitMQ发送消息接口
 */
public interface RabbitMQService {


    /**
     * 发送消息，
     * @param ex
     * @param routingKey
     * @param json
     */
    void sendMsgToDirect(String ex,String routingKey,String json);

    /**
     * 发送消息，
     * @param ex
     * @param routingKey
     * @param json
     */
    void sendMsgToTopic(String ex,String routingKey,String json);

    /**
     * 发送消息
     * 因为时fanout交换机，所以不用路由
     * @param ex
     * @param json
     */
    void sendMsgToFanout(String ex,String json);
}
